package cn.xinfei.xdecision.pulsar.model;

import lombok.Data;

@Data
public class XPulsarConsumerModel {
    private String topic;

    private String subscriptionName;

    private String consumerName;

    private int concurrentNum;

    public XPulsarConsumerModel(String topic, String subscriptionName, String consumerName,int concurrentNum) {
        this.topic = topic;
        this.subscriptionName = subscriptionName;
        this.consumerName = consumerName;
        this.concurrentNum = concurrentNum;
    }
}
